package com.yupi.springbootinit.mq;

import com.rabbitmq.client.Channel;
import com.rabbitmq.client.Connection;
import com.rabbitmq.client.ConnectionFactory;
import com.rabbitmq.client.MessageProperties;

import java.util.Scanner;

/**
 * @version 1.0
 * @Author HJY_Maker
 * @Date 2024/5/21 星期二 14:33
 */
/**
 * 两个生产者 发送消息
 */
public class MultiProducer {
    private static final String TASK_QUEUE_NAME = "multi_queue";

    public static void main(String[] argv) throws Exception {
        ConnectionFactory factory = new ConnectionFactory();
        factory.setHost("localhost");
        try (Connection connection = factory.newConnection();
             Channel channel = connection.createChannel()) {
            channel.queueDeclare(TASK_QUEUE_NAME, true, false, false, null);

            Scanner scanner = new Scanner(System.in);

            while (scanner.hasNext()) {
                String message = scanner.nextLine();
                channel.basicPublish("", TASK_QUEUE_NAME,//队列名称
                        MessageProperties.PERSISTENT_TEXT_PLAIN,//消息持久化，
                        message.getBytes("UTF-8"));
                System.out.println(" [x] Sent '" + message + "'");
            }


        }
    }
}
